package topology;

import org.apache.storm.topology.BasicOutputCollector;
import org.apache.storm.topology.OutputFieldsDeclarer;
import org.apache.storm.topology.base.BaseBasicBolt;
import org.apache.storm.tuple.Tuple;

/**
 * Created by Simon on 2018/10/23.
 */
public class KafkaSpoutBolt extends BaseBasicBolt {
    @Override public void execute(Tuple tuple, BasicOutputCollector basicOutputCollector) {
        //只做一个输出
        System.out.println(tuple.toString());
    }

    @Override public void declareOutputFields(OutputFieldsDeclarer outputFieldsDeclarer) {

    }
}